from utils.operators.bash import BashOperator

from spmi.time_sensor import time_after_02_00

jms_dim__dim_network_whole_massage_check = BashOperator(
    task_id='jms_dim__dim_network_whole_massage_check',
    email=['lukunming@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="spmi/dim/spmi/jms_dim_network_whole_massage_check/execute.sh",
    pool='unlimited_pool',
    # queue='pyspark',
    priority_weight=0,
)

jms_dim__dim_network_whole_massage_check << time_after_02_00